package com.yk.filedownload.DataTransfer.KafkaOp.impl;

import com.yk.collection.kafka.consumer.ResourceConsumer;
import com.yk.collection.kafka.producer.ResourceProducer;
import com.yk.filedownload.DataTransfer.KafkaOp.KafkaOperation;

/**
 * Project Name:cykfiledownload
 * File Name:KafkaOperationImpl
 * Package Name:com.yk.filedownload.DataTransfer.KafkaOp.impl
 * Date:2017\12\8 0008
 * Author:dengtianjia
 * Description:
 * Copyright (c) 2017, 重庆云凯科技有限公司 All Rights Reserved.
 */
public class KafkaOperationImpl implements KafkaOperation{

    public static ResourceConsumer consumer;

    public static ResourceProducer producter;


    @Override
    public ResourceConsumer getConsumer() {
        if(consumer ==  null){
            consumer = new ResourceConsumer("url",8);
        }
        return consumer;
    }

    @Override
    public ResourceProducer getProducter() {
        if(producter == null){
            producter = new ResourceProducer("url");
        }
        return producter;
    }
}
